# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator

jms_dep__yl_jms_tms_effective_state = BashOperator(
    task_id='jms_dep__yl_jms_tms_effective_state',
    execution_timeout=timedelta(minutes=50),
    email=['rongguangfan@jtexpress-scm.com','yl_etl@yl-scm.com'],
    bash_command="jms/ods/dep/yl_jms_tms_effective_state/execute.sh",
    pool='spmi_apack',
    retries=0,
    pool_slots=2,
)
